D = group A by $0 as b:LONG;
C = filter B by $0 > 0 PARALLEL 10;
X = FOREACH C GENERATE FLATTEN(B) ;
store B into "output";
b=(-1);
a = load '1.bin' using BinStorage as (a0, a1, a2);
DEFINE CMD `perDEFINE CMD `perl PigStreaming.pl - nameMap` input(stdin using PigStreaming(',')) output(stdout using PigStreaming(',')) input(stdin using PigStreaming(','));
X = FOREACH A GENERATE f2, (f2==1?1:COUNT(*));
X = FOREACH A GENERATE SIZE(*);